package com.atgm.mall.gmmallclub.config;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @ClassName QuartaService
 * @Description 定时任务业务
 * @Auther pdx
 * @Date 2021/11/3 14:14
 * @Verison 1.0
 **/
@Slf4j
@Component
public class QuartzConfig {

    /**
     * 注入Scheduler
     */
    @Autowired
    private Scheduler scheduler;


    /**
     * 新增任务
     * @param clazz Job类
     * @param name 名称
     * @param group 组名
     * @param cron 表达式
     * @param data 额外传入的值
     */
    public void addJobs(Class clazz,String name,String group,String cron,Object data){
        JobDataMap jobDataMap = new JobDataMap();
        if(data!=null){
            jobDataMap = JSON.parseObject(JSON.toJSONString(data),JobDataMap.class);
        }
        log.error("定时任务开始创建 名称：{} cron表达式：{}",name,cron);
        JobDetail jobDetail = JobBuilder.newJob(clazz)
                /**添加认证信息，有3种重写的方法，我这里是其中一种，可以查看源码看其余2种*/
                .withIdentity(name, group)
                .build();//执行

        CronTrigger trigger = TriggerBuilder.newTrigger()
                .usingJobData(jobDataMap)
                /**添加认证信息，有3种重写的方法，我这里是其中一种，可以查看源码看其余2种*/
                .withIdentity(name, group)
                /**立即生效*/
                .startNow()
                /**添加执行规则，SimpleTrigger、CronTrigger的区别主要就在这里**/
                .withSchedule(CronScheduleBuilder.cronSchedule(cron))
                .build();//执行
        try {
            scheduler.scheduleJob(jobDetail, trigger);
            log.info("定时任务创建成功 名称：{} cron表达式：{}",name,cron);
        } catch (SchedulerException e) {
            log.error("定时任务错误 名称：{} cron表达式：{}",name,cron);
            e.printStackTrace();
        }
    }

    /**
     * 删除任务
     * @param name 名称
     * @param group 组
     */
    public void deleteJobs(String name,String group){
        log.error("定时任务开始删除 名称：{} 组：{}",name,group);
        JobKey jobKey = new JobKey(name,group);
        try {
            if (scheduler.checkExists(jobKey)) {
                scheduler.deleteJob(jobKey);
                log.error("定时任务删除成功 名称：{} 组：{}",name,group);
            }
        } catch (SchedulerException e) {
            log.error("定时任务删除错误 名称：{} 组：{}",name,group);
            e.printStackTrace();
        }
    }

    /**
     * 更新任务
     * @param classes
     * @param name
     * @param group
     * @param cron
     */
    public void updateJobs(Class classes,String name,String group,String cron,Object data){
        //删除原来的
        deleteJobs(name,group);
        //新增
        addJobs(classes,name,group,cron,data);
    }

}


